/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */
package org.sbbs.nettydisruptor.timeserver;

import org.sbbs.nettydisruptor.base.DisruptorAdapterBy41xHandler;
import org.sbbs.nettydisruptor.base.Executor;
import org.sbbs.nettydisruptor.base.Session;

/**
 *
 * @author MACHENIKE
 */
public class TimeServerDisruptorHandler extends DisruptorAdapterBy41xHandler<Object> {
    private int counter;
    @Override
    protected Executor newExecutor(Session session, Object msg) {
        System.out.println("The time server receive order : " + msg
		+ " ; the counter is : " + ++counter);
        return new TimeServerExecutor(session, msg);
    }
}
